package com.umeox.watch.moto.dataservice.mqtt.request;


import com.umeox.moto.mqtt.request.MqttPublishRequest;
import com.umeox.watch.moto.dataservice.mqtt.Topic;

import java.util.concurrent.atomic.AtomicLong;

public class PingRequest extends MqttPublishRequest {

    private static AtomicLong mCount = new AtomicLong();

    public PingRequest(){
        this.topic = Topic.PING_TOPIC;
        this.payloadObj = new byte[]{0};
        this.isRPC = false;
        this.qos = 1;
        this.requestId = mCount.incrementAndGet() + "";
    }
}
